package com.atguigu.tingshu.common.constant;

import org.springframework.context.annotation.Description;

/**
 * Author:huzhongkui
 * Date: 2024-03-28  23:21
 */
@Description("kafka的常量类")
public class KafkaConstant {


    // 定义主题后缀
    public static final String TOPIC_SUFFIX = "_topic";
    // 定义消息前缀
    public static final String MSG_PREFIX = "kafka_msg";


    /**
     * 用户账户队列
     */
    public static final String USER_ACCOUNT_REGISTER = "user.account.register";


    /**
     * 专辑
     */
    public static final String QUEUE_ALBUM_UPPER = "tingshu.album.upper";
    public static final String QUEUE_ALBUM_LOWER = "tingshu.album.lower";
    public static final String QUEUE_ALBUM_STAT_UPDATE = "tingshu.album.stat.update";
    public static final String QUEUE_ALBUM_ES_STAT_UPDATE = "tingshu.album.es.stat.update";
    public static final String QUEUE_ALBUM_RANKING_UPDATE = "tingshu.album.ranking.update";


    /**
     * 声音
     */


    public static final String QUEUE_TRACK_STAT_UPDATE = "tingshu.track.stat.update";


    /**
     * 专辑or声音
     */
    public static final String QUEUE_ALBUM_TRACK_STAT_UPDATE = "tingshu.album.track.stat.update";


    /**
     * 账户
     */
    public static final String QUEUE_ACCOUNT_UNLOCK = "tingshu.account.unlock";
    public static final String QUEUE_ACCOUNT_MINUS = "tingshu.account.minus";// 扣减账户&&解除锁定


    /**
     * 支付
     */
    public static final String QUEUE_ORDER_PAY_SUCCESS = "tingshu.order.pay.success";
    public static final String QUEUE_RECHARGE_PAY_SUCCESS = "tingshu.recharge.pay.success";
    public static final String QUEUE_USER_PAY_RUNNING_WATER = "tingshu.order.pay.success.user.running_water";
}
